package com.muyu.kafka.service;

import com.muyu.kafka.domain.Data1;
import com.muyu.kafka.domain.Data2;
import com.muyu.kafka.domain.Data3;

import java.math.BigInteger;
import java.util.Date;
import java.util.List;

/**
 * @ClassName KafkaService
 * @Description 描述
 * @Author ShiYu.Cui
 * @Date 2024/4/11 20:22
 */
public interface KafkaService {
    Integer findData1(BigInteger id);

    void insertData1(Data1 value);

    void updateData1(Data1 value);

    Integer findData2(BigInteger id);

    void insertData2(Data2 value2);

    void updateData2(Data2 value2);

    Integer findData3(BigInteger id);

    void insertData3(Data3 value);

    void updateData3(Data3 value);
    List<Data1> findData1All();

    Data2 finddata2(BigInteger id);
    Data3 finddata3(BigInteger id);

    void delete1ById(BigInteger id);

    void delete2ById(BigInteger id);

    void delete3ById(BigInteger id);

    List<Data1> findData1ByTime(Date time);
}
